package com.winter.process;

import com.winter.util.canalUtil.CanalRowChange;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

//@Component
//public class FssFinancialProcess extends BaseProcess{
//
//	private static final Logger logger = LoggerFactory.getLogger(FssFinancialProcess.class);
//	@Autowired
//	private IFssFinancialLossesDetailService fssFinancialLossesDetailService;
//
//	@Override
//	public boolean processInsert(CanalRowChange rowChange) {
//		try {
//			List<FssFinancialLossesDetail> data = super.processConvert(rowChange, FssFinancialLossesDetail.class, true);
//			logger.info("添加了"+data);
//			fssFinancialLossesDetailService.insertBatch(data);
//		} catch (InstantiationException e) {
//			e.printStackTrace();
//		} catch (IllegalAccessException e) {
//			e.printStackTrace();
//		}
//
//		return true;
//	}
//
//	@Override
//	public boolean processUpdate(CanalRowChange rowChange) {
//		try {
//			List<FssFinancialLossesDetail> data = super.processConvert(rowChange, FssFinancialLossesDetail.class, false);
//			List<FssFinancialLossesDetail> data2 = super.processConvert(rowChange, FssFinancialLossesDetail.class, true);
//			logger.info("修改前："+data);
//			logger.info("修改后："+data2);
//			fssFinancialLossesDetailService.insertOrUpdateAllColumnBatch(data2);
//			return true;
//		} catch (InstantiationException e) {
//			e.printStackTrace();
//		} catch (IllegalAccessException e) {
//			e.printStackTrace();
//		}
//		return false;
//
//	}
//
//	@Override
//	public boolean processDelete(CanalRowChange rowChange) {
//		try {
//			List<FssFinancialLossesDetail>	data = super.processConvert(rowChange, FssFinancialLossesDetail.class, false);
//			logger.info("删除前："+data);
//			return true;
//		} catch (InstantiationException e) {
//			e.printStackTrace();
//		} catch (IllegalAccessException e) {
//			e.printStackTrace();
//		}
//		return false;
//	}
//
//}
